Руководство для начинающих¶

Поиск кортежей на вкладке Tuples¶

В TCM во вкладке Tuples можно:

• просмотреть содержимое спейса на каждом узле кластера;

• найти все кортежи, которые удовлетворяют условию, заданному в виде выражения с оператором сравнения.

TCM поддерживает следующие операторы сравнения:

• == – равно;

• > – больше чем;

• < – меньше чем;

• >= – больше чем или равно;

• <= – меньше чем или равно.

Условие поиска имеет следующую структуру:

index_name comparator value

Здесь:

• index_name – левая часть выражения. Содержит название индекса;

• comparator – оператор сравнения (>, >=, ==, <=, <). Должен быть отделен пробелами от левой и правой частей выражения;

• value – правая часть выражения. Содержит строковое, численное или булево значение. Строковое значение при этом должно быть заключено в двойные кавычки ("").

Примеры

Пример поиска ниже возвращает кортежи с ID больше 1:

id > 1

В примере ниже поиск возвращает кортежи, в которых индекс band_name равен значению Roxette:

band_name == "Roxette"

Запрос на выборку по условию¶

Модуль CRUD поддерживает запросы на выборку (SELECT) с множественными условиями, кластер при этом рассматривается как единый спейс. Условия могут содержать имена полей и имена индексов. Рекомендуемым первым условием является TREE-индекс, он позволяет уменьшить число сканируемых кортежей и не выполнять полное сканирование.

Запрос имеет следующую структуру:

crud.select(space_name, conditions, opts)

Здесь:

• space_name – название спейса. Тип: string;

• conditions – массив условий для выборки. Тип: table. Каждое условие – это таблица вида {operator, field-identifier, value}:

  • operator – оператор сравнения (>, >=, == или =, <=, <). Тип: string;

  • field-identifier – идентификатор поля. Тип: string. Это может быть имя поля или название индекса;

  • value – искомое значение;

• opts – дополнительные параметры. Поддерживаемые параметры:

  • first – максимальное количество возвращаемых элементов. Тип: number. Если указано отрицательное значение, возвращаются элементы, стоящие за значением опции after;

  • after – курсор пагинации на первый элемент. Тип: table;

  • batch_size – количество кортежей, которое будет обработано за один запрос к хранилищу. Тип: number;

  • bucket_id – идентификатор сегмента. Тип: number или cdata;

  • force_map_call – если задано значение true, вызор map выполняется без оптимизаций, даже если указано полное условие равенства первичного ключа. Тип: boolean;

  • timeout – время ожидания выполнения vshard.call в секундах. Тип: number. Если роутер не может определить шард с указанным bucket_id, он будет повторять попытку до истечения времени ожидания;

  • request_timeout – время ожидания в секундах, служит защитой от зависания реплик. Тип: number. Передавать параметры request_timeout и timeout нужно вместе с учетом следующего условия: timeout > request_timeout. Параметр request_timeout определяет, сколько времени может занять одна попытка запроса. По истечении этого времени (когда возникает ошибка TimedOut) роутер повторяет запрос на следующей реплике, если значение таймаута еще не истекло; Может быть задан только при mode = read. Значение по умолчанию совпадает со значением опции timeout, передаваемой пользователем;

  • fields – имена полей для получения подмножества полей. Тип: table;

  • fullscan – если задано значение true, критическая запись в журнале будет пропущена при потенциально длительном select. Тип: boolean;

  • mode – режим доступа. Тип: string. Поддерживаемые значения: read, write. Если задано значение write, запрос на выборку выполняется на мастер-узле. Значение по умолчанию: read;

  • prefer_replica – если задано значение true, предпочитаемой целью для выполнения запроса на выборку будет один из экземпляров реплики. Тип: boolean;

  • balance – если задано значение true, включена балансировка нагрузки. Тип: boolean;

  • vshard_router – имя узла роутера vshard. Тип: string или table;

  • yield_every – количество кортежей, обрабатываемых в хранилище для выполнения yield после завершения обработки. Тип: number. Значение опции должно быть больше 0. Значение по умолчанию: 1000;

  • fetch_latest_metadata – если задано значение true, опция гарантирует актуальность метаданных (формат спейса) в первом возвращаемом значении. Если указано значение false, опция может не учитывать последнюю миграцию формата данных. Тип: boolean. Значение по умолчанию: false.

Пример

Выполнить такой запрос можно в TCM на вкладке Stateboard. Для этого:

1. На вкладке Stateboard выберите набор реплик (в примере это router-msk).

2. Выберите узел роутера (router-msk) и в открывшемся окне перейдите на вкладку Terminal.

3. Во вкладке Terminal получите кортежи с помощью метода crud.select().

crud.select('bands', {{'>=', 'year', 1980}}, {first = 10})
---
- metadata: [{'name': 'id', 'type': 'integer'}, {'name': 'bucket_id', 'type': 'unsigned'},
    {'name': 'band_name', 'type': 'string'}, {'name': 'year', 'type': 'integer'}]
  rows:
  - [1, 12477, 'Roxette', 1986]
  - [3, 11804, 'Ace of Base', 1988]
...

В примере возвращаются музыкальные группы, которые были образованы в 1980 году или позднее.

Также выполнить запрос crud.select() можно через утилиту tt CLI, пример подключения к роутеру приведен ранее в разделе Запросы к данным c помощью модуля CRUD.

Имитация отказа в Docker Compose¶

Для имитации отказа вернитесь в локальный терминал и остановите узлы кластера с помощью команды docker compose stop:

cd cluster && docker compose stop tarantool-storage-1-msk
cd cluster && docker compose stop tarantool-storage-2-spb

Оба узла отмечены в TCM серым цветом – эти экземпляры теперь недоступны. Чтобы открыть список ошибок, нажмите на любой из этих узлов и перейдите в раздел с ошибками. Наборы реплик отмечены красным, так как в них есть нерабочий узел кластера. Если в момент выключения узел был лидером набора реплик, будет выбран новый лидер. Задать это можно в опции конфигурации replication.failover:

replication:
  failover: election

Проверка работы кластера¶

Чтобы проверить, что остановленные узлы не мешают работе кластера, во вкладке Terminal добавьте несколько новых записей:

crud.insert_object('bands', {id = 4, band_name = 'The Beatles', year = 1960})

Посмотрите повторно содержимое таблицы:

crud.select('bands')

Ответ выглядит так:

---
- metadata: [{'name': 'id', 'type': 'integer'}, {'name': 'bucket_id', 'type': 'unsigned'},
    {'name': 'band_name', 'type': 'string'}, {'name': 'year', 'type': 'integer'}]
  rows:
  - [1, 12477, 'Roxette', 1986]
  - [2, 21401, 'Scorpions', 1965]
  - [3, 11804, 'Ace of Base', 1988]
  - [4, 28161, 'The Beatles', 1960]
- null
...